// Copyright (c) 2013 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "content/browser/streams/stream_handle_impl.h"

#include <stddef.h>

#include "base/bind.h"
#include "base/location.h"
#include "base/threading/thread_task_runner_handle.h"
#include "content/browser/streams/stream.h"

namespace content {

namespace {

    void RunCloseListeners(const std::vector<base::Closure>& close_listeners)
    {
        for (size_t i = 0; i < close_listeners.size(); ++i)
            close_listeners[i].Run();
    }

} // namespace

StreamHandleImpl::StreamHandleImpl(const base::WeakPtr<Stream>& stream)
    : stream_(stream)
    , url_(stream->url())
    , stream_task_runner_(base::ThreadTaskRunnerHandle::Get().get())
{
}

StreamHandleImpl::~StreamHandleImpl()
{
    stream_task_runner_->PostTaskAndReply(
        FROM_HERE, base::Bind(&Stream::CloseHandle, stream_),
        base::Bind(&RunCloseListeners, close_listeners_));
}

const GURL& StreamHandleImpl::GetURL()
{
    return url_;
}

void StreamHandleImpl::AddCloseListener(const base::Closure& callback)
{
    close_listeners_.push_back(callback);
}

} // namespace content
